package cn.me.alphamq.client.consumer;

import cn.me.alphamq.common.entity.Message;

import java.util.List;

/**
 * 消费消息的监听器
 *
 * @author f
 */
public interface MessageConsumeListener {

    /**
     * 消费消息
     * TODO 如果消费只使用了 Message 的 body 字段，则可以封装一个新的类
     *
     * @param messageList 一批消息
     * @return 消费的结果
     */
    ConsumeResult consume(List<Message> messageList);

}
